//package com.jd.jstable.test.mq.kafka;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
///**
// * kafka监听器启动
// * 自动监听是否有消息需要消费
// * @author wangb
// *
// */
//public class KafkaConsumerServer implements MessageListener<String, String> {
//    protected final Logger LOG = LoggerFactory.getLogger("kafkaConsumer");
//    /**
//     * 监听器自动执行该方法
//     *     消费消息
//     *     自动提交offset
//     *     执行业务代码
//     *     （high level api 不提供offset管理，不能指定offset进行消费）
//     */
//    @Override
//    public void onMessage(ConsumerRecord<String, String> record) {
//        LOG.info("=============kafkaConsumer开始消费=============");
//        String topic = record.topic();
//        String key = record.key();
//        String value = record.value();
//        long offset = record.offset();
//        int partition = record.partition();
//        LOG.info("-------------topic:"+topic);
//        LOG.info("-------------value:"+value);
//        LOG.info("-------------key:"+key);
//        LOG.info("-------------offset:"+offset);
//        LOG.info("-------------partition:"+partition);
//        LOG.info("~~~~~~~~~~~~~kafkaConsumer消费结束~~~~~~~~~~~~~");
//    }
//
//}